var db = require('../database/db');
var collectionName;

function init(collectionName) {
  db.bind(collectionName);
}

function append(collectionName, data, callback) {
  db[collectionName].save(data, function(err, doc){

    if (err) {
      console.log(err);
    } else {
      // console.log(doc.result);
      callback && callback();
    }

    // db.close();
  });
}

function remove() {

}

function update() {

}

function query(collectionName, filter, callback) {
  db[collectionName].find(filter || {}).toArray(function(err, result) {

    if (err) {
      console.log(err);
    } else {
      callback && callback(result);
    }
    db.close();
  });
}

module.exports = {
  init: init ,
  append: append ,
  remove: remove ,
  update: update ,
  query: query
}
